home *** CD-ROM | disk | FTP | other *** search
/ PC World Komputer 2010 April / PCWorld0410.iso / hity wydania / Ubuntu 9.10 PL / karmelkowy-koliberek-desktop-9.10-i386-PL.iso / casper / filesystem.squashfs / usr / lib / python2.5 / site-packages / debconf.py < prev    next >
Encoding:
Python Source  |  2009-10-02  |  6.2 KB  |  185 lines
  1. # Copyright:
  2. #   Moshe Zadka (c) 2002
  3. #   Canonical Ltd. (c) 2005 (DebconfCommunicator)
  4. #
  5. # Redistribution and use in source and binary forms, with or without
  6. # modification, are permitted provided that the following conditions
  7. # are met:
  8. # 1. Redistributions of source code must retain the above copyright
  9. #    notice, this list of conditions and the following disclaimer.
  10. # 2. Redistributions in binary form must reproduce the above copyright
  11. #    notice, this list of conditions and the following disclaimer in the
  12. #    documentation and/or other materials provided with the distribution.
  13. # 
  14. # THIS SOFTWARE IS PROVIDED BY AUTHORS AND CONTRIBUTORS ``AS IS'' AND
  15. # ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  16. # IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  17. # ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHORS OR CONTRIBUTORS BE LIABLE
  18. # FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  19. # DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
  20. # OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
  21. # HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  22. # LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  23. # OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  24. # SUCH DAMAGE.
  25.  
  26. import sys, os
  27. import errno
  28. import re
  29. try:
  30.     import subprocess
  31.     using_subprocess = True
  32. except ImportError:
  33.     import popen2
  34.     using_subprocess = False
  35. import fcntl
  36.  
  37. class DebconfError(Exception):
  38.     pass
  39.  
  40. LOW, MEDIUM, HIGH, CRITICAL = 'low', 'medium', 'high', 'critical'
  41.  
  42. class Debconf:
  43.  
  44.     def __init__(self, title=None, read=None, write=None):
  45.         for command in ('capb set reset title input beginblock endblock go get'
  46.                         ' register unregister subst fset fget previous_module'
  47.                         ' visible purge metaget exist version settitle'
  48.                         ' info progress data').split():
  49.             self.setCommand(command)
  50.         self.read = read or sys.stdin
  51.         self.write = write or sys.stdout
  52.         sys.stdout = sys.stderr
  53.         self.setUp(title)
  54.  
  55.     def setUp(self, title):
  56.         self.version = self.version(2)
  57.         if self.version[:2] != '2.':
  58.             raise DebconfError(256, "wrong version: %s" % self.version)
  59.         self.capabilities = self.capb().split()
  60.         if title:
  61.             self.title(title)
  62.  
  63.     def setCommand(self, command):
  64.         setattr(self, command,
  65.                lambda *args, **kw: self.command(command, *args, **kw))
  66.  
  67.     def command(self, command, *params):
  68.         command = command.upper()
  69.         self.write.write("%s %s\n" % (command, ' '.join(map(str, params))))
  70.         self.write.flush()
  71.  
  72.         while True:
  73.             try:
  74.                 resp = self.read.readline().rstrip('\n')
  75.                 break
  76.             except IOError, e:
  77.                 if e.errno == errno.EINTR:
  78.                     continue
  79.                 else:
  80.                     raise
  81.  
  82.         if ' ' in resp:
  83.             status, data = resp.split(' ', 1)
  84.         else:
  85.             status, data = resp, ''
  86.         status = int(status)
  87.         if status == 0:
  88.             return data
  89.         elif status == 1:   # unescaped data
  90.             unescaped = ''
  91.             for chunk in re.split(r'(\\.)', data):
  92.                 if chunk.startswith('\\') and len(chunk) == 2:
  93.                     if chunk[1] == 'n':
  94.                         unescaped += '\n'
  95.                     else:
  96.                         unescaped += chunk[1]
  97.                 else:
  98.                     unescaped += chunk
  99.             return unescaped
  100.         else:
  101.             raise DebconfError(status, data)
  102.  
  103.     def stop(self):
  104.         self.write.write('STOP\n')
  105.         self.write.flush()
  106.  
  107.     def forceInput(self, priority, question):
  108.         try:
  109.             self.input(priority, question)
  110.             return 1
  111.         except DebconfError, e:
  112.             if e.args[0] != 30:
  113.                 raise
  114.         return 0
  115.  
  116.     def getBoolean(self, question):
  117.         result = self.get(question)
  118.         return result == 'true'
  119.  
  120.     def getString(self, question):
  121.         return self.get(question)
  122.  
  123.  
  124. class DebconfCommunicator(Debconf, object):
  125.     def __init__(self, owner, title=None, cloexec=False):
  126.         args = ['debconf-communicate', '-fnoninteractive', owner]
  127.         if using_subprocess:
  128.             self.dccomm = subprocess.Popen(args, stdin=subprocess.PIPE, stdout=subprocess.PIPE, close_fds=True)
  129.             read = self.dccomm.stdout
  130.             write = self.dccomm.stdin
  131.         else:
  132.             self.dccomm = popen2.Popen3(args)
  133.             read = self.dccomm.fromchild
  134.             write = self.dccomm.tochild
  135.         super(DebconfCommunicator, self).__init__(title=title,
  136.                                                   read=read,
  137.                                                   write=write)
  138.         if cloexec:
  139.             fcntl.fcntl(self.read.fileno(), fcntl.F_SETFD, fcntl.FD_CLOEXEC)
  140.             fcntl.fcntl(self.write.fileno(), fcntl.F_SETFD, fcntl.FD_CLOEXEC)
  141.  
  142.     def shutdown(self):
  143.         if self.dccomm is not None:
  144.             if using_subprocess:
  145.                 self.dccomm.stdin.close()
  146.                 self.dccomm.stdout.close()
  147.             else:
  148.                 self.dccomm.tochild.close()
  149.                 self.dccomm.fromchild.close()
  150.             self.dccomm.wait()
  151.             self.dccomm = None
  152.  
  153.     # Don't rely on this; call .shutdown() explicitly.
  154.     def __del__(self):
  155.         try:
  156.             self.shutdown()
  157.         except AttributeError:
  158.             pass
  159.  
  160.  
  161. if ('DEBCONF_USE_CDEBCONF' in os.environ and
  162.     os.environ['DEBCONF_USE_CDEBCONF'] != ''):
  163.     _frontEndProgram = '/usr/lib/cdebconf/debconf'
  164. else:
  165.     _frontEndProgram = '/usr/share/debconf/frontend'
  166.  
  167. def runFrontEnd():
  168.     if 'DEBIAN_HAS_FRONTEND' not in os.environ:
  169.         os.environ['PERL_DL_NONLAZY']='1'
  170.         os.execv(_frontEndProgram, [_frontEndProgram, sys.executable]+sys.argv)
  171.  
  172.  
  173. if __name__ == '__main__':
  174.     runFrontEnd()
  175.     db = Debconf()
  176.     db.forceInput(CRITICAL, 'bsdmainutils/calendar_lib_is_not_empty')
  177.     db.go()
  178.     less = db.getBoolean('less/add_mime_handler')
  179.     aptlc = db.getString('apt-listchanges/email-address')
  180.     db.stop()
  181.     print db.version
  182.     print db.capabilities
  183.     print less
  184.     print aptlc
  185.